#include "head.h"
#include "taskQueue.h"

int queueInit(taskQueue_t *ptaskQueue){
    bzero(ptaskQueue,sizeof(taskQueue_t));
    return 0;
}

int enQueue(taskQueue_t *ptaskQueue, int netfd){
    node_t *p = (node_t *)calloc(1,sizeof(node_t));
    p->data = netfd;
    if(ptaskQueue->queueSize == 0){
        ptaskQueue->front = p;
        ptaskQueue->rear = p;
    }else{
        ptaskQueue->rear->pNext = p;
        ptaskQueue->rear = p;
    }
    ptaskQueue->queueSize++;
    return 0;
}

int deQueue(taskQueue_t *ptaskQueue){
    node_t *p = ptaskQueue->front;
    ptaskQueue->front = p->pNext;
    free(p);
    ptaskQueue->queueSize--;
    return 0;
}

int printQueue(taskQueue_t *ptaskQueue){
    node_t *p = ptaskQueue->front;
    for(;p!=NULL;p=p->pNext){
        printf("%3d",p->data);
    }
    printf("\n");
    return 0;
}

//int main(){
//    taskQueue_t taskQueue;
//    queueInit(&taskQueue);
//    for(int i = 0; i < 10; i++){
//        enQueue(&taskQueue,i);
//        printQueue(&taskQueue);
//    }
//    printf("----------------------\n");
//    for(int i = 0; i < 9; i++){
//        deQueue(&taskQueue);
//        printQueue(&taskQueue);
//    }
//    return 0;
//}
